import celery

broker = 'redis://127.0.0.1:6379/1'

backend = 'redis://127.0.0.1:6379/2'

app = celery.Celery('test', broker=broker, backend=backend)


@app.task
def add(a, b):
    return a + b


@app.task
def mul(a, b):
    return a * b
